package com.haoran.grope.server;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
//@RabbitListener(bindings= {@QueueBinding(exchange = @Exchange(value = "amp-topic-exchange"), value = @Queue("debug"))})
public class RabbitMQServer3 {

	@RabbitListener(queues="error")
	public void receive(String message) throws InterruptedException {
		System.out.println("---RabbitMQServer3-----receive ------- " + message);
	}
	
}